require_relative '../lib/kafka_client'

require 'byebug'

byebug
10.times do
  datas = 10.times.map{rand(1000).to_s}
  KafkaClient.send_message datas
end

# at_exit {
#   kafka.close
# }
